package thread;

public class ThreadPoolDemo {
    public static void main(String[] args) {
        ExecutorService threadPool = Executors.newFixedThreadPool(2);
        for (int i = 0; i < 5; i++) {
            Runnable r = new Runnable() {
                public void run() {
                    Thread t = Thread.currentThread();
                    System.out.println(t.getName() + ":正在执行任务");
                    Thread.sleep(5000);
                    System.out.println(t.getName() + ":任务执行完毕");
                }
            };
            threadPool.execute(r);
            System.out.println("将一个任务交给了线程池");
        }
        //threadPool.shutdown();  // 运行完关闭线程池
        threadPool.shutdownNow();  //强行关闭正在执行的任务
        System.out.println("线程池关闭");
    }
}

